package com.hefei.garden.config.kafka.constant;

/**
 * @author: devil
 * @Date: 2022/8/21 16
 * @Description:
 */
public class KafkaConstant {

    /**
     * 主题
     */
    public static final String TOPIC_DEMO_A = "topic-demo-a";
    public static final String TOPIC_DEMO_B = "topic-demo-b";
    public static final String TOPIC_ORDER = "topic-order";
    public static final String TOPIC_CHENYUXIU = "topic-chenyuxiu";
    public static final String TOPIC_QIANQIAN = "topic-qianqian";
    public static final String DATABASE_INSERT_TOPIC = "DATABASE_INSERT_TOPIC";


    /**
     * 消费者组
     */
    public static final String GROUP_1 = "group_1";
    public static final String GROUP_2 = "group_2";
    public static final String GROUP_3 = "group_3";
    public static final String GROUP_4 = "group_4";
    public static final String GROUP_5 = "group_5";

    /**
     * 分区
     */
    public static final int PARTITION_0 = 0;
    public static final int PARTITION_1 = 1;
    public static final int PARTITION_2 = 2;
    public static final int PARTITION_3 = 3;
    public static final int PARTITION_4 = 4;

}
